package com.kyrie.kafka;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

/***
 * 描述: kafka配置读取类
 *
 * @author wuxiang
 * @date 2020-04-24 13:26
 */
@ConfigurationProperties(prefix = "interface.kafka")
@Component
public class KafKaConfiguration {

    private String bootstrapServers;

    private KafkaProductConf producer;

    private KafkaConsumerConf consumer;

    public String getBootstrapServers() {
        return bootstrapServers;
    }

    public void setBootstrapServers(String bootstrapServers) {
        this.bootstrapServers = bootstrapServers;
    }

    public KafkaProductConf getProducer() {
        return producer;
    }

    public void setProducer(KafkaProductConf producer) {
        this.producer = producer;
    }

    public KafkaConsumerConf getConsumer() {
        return consumer;
    }

    public void setConsumer(KafkaConsumerConf consumer) {
        this.consumer = consumer;
    }
}
